package com.wn.sk.product.core.product;

import com.wn.common.api.order.dto.OrderPayDto;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 消息的生产者
 * 把 需要付款的信息发送到mq中 进行 付款的计时
 */
@Component
public class OrderProducer {


    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendOrder(OrderPayDto orderDto){

        /**
         *  发送消息
         *  参数1：交换机
         *  参数2：路由key
         *  参数3：消息
         */
        rabbitTemplate.convertAndSend(
                "order-exchange","order."+orderDto.getOrderSn(),orderDto);
    }
}